package com.gk.kafkaconsumer1.process;

import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.messaging.Processor;
import org.springframework.integration.annotation.ServiceActivator;

@EnableBinding(MyProcessor.class)
public class TransFormService {

    @ServiceActivator(inputChannel = MyProcessor.INPUT,outputChannel = MyProcessor.OUTPUT)
    public Object transform(Object payload){
        System.out.println("消息中转站："+payload);
        return payload;
    }
}
